package com.example.geguo.custom;

public class MyRxImpl {
	public  void run() {
		ObservableImp.create(new Command<String>() {
			/**
			 * @param emmitter 其实我是Command 对象 的 exectue 方法
			 */
			@Override
			public void subscribe(Emmitter<String> emmitter) {
//			    具体的指令再交给 Emmitter 去执行
				emmitter._next("Hello");
				emmitter._completed();
			}
		}).subscribe(new Observer<String>() {
			@Override
			public void onNext(String element) {
				System.out.println("H:"+element);
			}

			@Override
			public void onCompleted() {
				System.out.println(this.getClass().getSimpleName() + ":onCompleted");
			}

			@Override
			public void onErrror(Throwable e) {

			}
		});
	}
}
